package com.leezai.mqtt.handler;

import com.leezai.mqtt.dto.MessageWrapper;

public interface MessageHandler {

    /**
     * 将消息添加到处理队列中
     * @param message 消息包装器
     */
    void addMessage(MessageWrapper message);

    /**
     * 关闭消息处理器，释放所有资源
     * 包括线程池、连接等资源的清理
     */
    void shutdown();

    /**
     * 启动消息处理线程
     * 对于同步处理的实现可以为空操作
     */
    void startProcessing();
}
